<?php
// a.php
// 伪代码如下：
// 
ini_set("display_errors", "On");
error_reporting(E_ALL | E_STRICT);
require_once "beanstalk.php";

//接受参数
//$user  = $_POST['uid'];  //发微博的用户
//$content = $_POST['content'];  //发送内容
$user  = '111';  //发微博的用户
$content = 'fgbgfd';  //发送内容
// 插入微博 
// 取出当前插入微博的id => wid
// 查找出用户的所有粉丝uid => fensi
// 把推送放进队列
newtask(99,array(23,54,76,98));
//newtask($wid,$fensi);
function newtask($wid,$fensi)
{
	//echo 'sdsd';exit;
    $beanstalk = new Client();

    $beanstalk->connect();

    $beanstalk->useTube('test');
    
    foreach ($fensi as $key => $value) {
        //参数说明  优先级  延迟执行  执行超时  任务字符串
        $task = $value . "#" . $wid;   //  粉丝id和微博id
        $beanstalk->put( 1024,  0,   60,   $task );
    }
    
    $beanstalk->disconnect();
}